/********************************************************************
	File :			BroadcastStreamer.h
	Creation date :	2012/01/29

	License :			Copyright 2010 Ahmed Charfeddine, http://www.pushframework.com

				   Licensed under the Apache License, Version 2.0 (the "License");
				   you may not use this file except in compliance with the License.
				   You may obtain a copy of the License at

					   http://www.apache.org/licenses/LICENSE-2.0

				   Unless required by applicable law or agreed to in writing, software
				   distributed under the License is distributed on an "AS IS" BASIS,
				   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
				   See the License for the specific language governing permissions and
				   limitations under the License.


*********************************************************************/
#ifndef BroadcastStreamer__INCLUDED
#define BroadcastStreamer__INCLUDED

#pragma once

namespace PushFramework
{

	class LogicalConnectionImpl;
	typedef LogicalConnectionImpl* ItemPtr;
	typedef unordered_set<ItemPtr> itemSetT;

	enum EventsBits
	{
		ADD_ITEM		 		= 0x01,
		REMOVE_ITEM			 	= 0x02, 
		AWAKE_ALL		 		= 0x04, 
	};

class BroadcastStreamer
{
public:
    BroadcastStreamer(void);
    virtual ~BroadcastStreamer(void);
    
	void addItem(ItemPtr pItem);
	void removeItem(ItemPtr pItem);
	void awakeAll();

public:

	int getItemsCount();
	void start();
	void stop();

private:
	//
	itemSetT checkList;
	itemSetT newItems;
	itemSetT removedItems;
	//
	short eventBits;
	int itemsCount;
	bool shouldStop;
	ThreadHandleType hThread;
	CRITICAL_SECTION cs_SharedLists;

private:
	void doWork();
	void clearRemovedItems();
	void processAwakedItems(itemSetT& activeSet);
	bool processItem(ItemPtr pItem);
	//
#ifdef Plateform_Windows
	static DWORD WINAPI threadProc(LPVOID lpVoid);
#else
#ifdef Plateform_Linux
	static void* threadProc(void* lpVoid);
#endif
#endif

};
}
#endif // BroadcastStreamer__INCLUDED
